package com.kafka.service;

import com.kafka.rest.CreateProductRestModel;

import java.util.concurrent.ExecutionException;

public interface ProductService {
    String createProduct(CreateProductRestModel model) throws ExecutionException, InterruptedException;
    String createProductSync(CreateProductRestModel model) throws ExecutionException, InterruptedException;

}
